package cn.com.greatwall.kafka.service.impl;

import org.springframework.stereotype.Service;

import cn.com.greatwall.kafka.config.InitConfig;
import cn.com.greatwall.kafka.service.ElasticsearchService;
import cn.com.greatwall.kafka.util.ElasticsearchUtil;
import lombok.RequiredArgsConstructor;

/**
 * @Author herw
 * @Time 2021-04-16 13:09:58
 * @Version 1.0
 * @Description: TODO(用一句话描述该文件做什么)
 */
@Service
@RequiredArgsConstructor
public class ElasticsearchServiceImpl implements ElasticsearchService {
    private final InitConfig initConfig;
    private ElasticsearchUtil elasticsearchUtil;
    
    @Override
    public String getMonitorElasticsearchIndexName() {
        return initConfig.getMonitorElasticsearchIndexName();
    }

    @Override
    public ElasticsearchUtil getESDB() {
        return elasticsearchUtil;
    }
}
